package com.songjia.stream.test01;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Processor;

/**
 * 
 * 
 * @Description: 直接使用Processor
 *
 * @author: songjia 
 * @date: 2018年3月27日 上午10:40:02
 */
@EnableBinding(Processor.class)
public class MyProcessor {

	@StreamListener(Processor.INPUT)
	public void hendle(String message) {
		System.out.println("MyProcessor收到消息：" + message);
	}
	
}
